Personal Computer World 2009 February/PCWFEB09.iso/Software/Linux/Kubuntu 8.10/kubuntu-8.10-desktop-i386.iso/casper/filesystem.squashfs/usr/lib/python2.5/idlelib/PyShell.pyc

Python Compiled Bytecode | 2008-10-29 | 45.3 KB | 1,496 lines

# Source Generated with Decompyle++
# File: in.pyc (Python 2.5)

import os
import os.path as os
import sys
import string
import getopt
import re
import socket
import time
import threading
import traceback
import types
import macosxSupport
import linecache
from code import InteractiveInterpreter

try:
    from Tkinter import *
except ImportError:
    print >>sys.__stderr__, "** IDLE can't import Tkinter.  Your Python may not be configured for Tk. **"
    sys.exit(1)

import tkMessageBox
from EditorWindow import EditorWindow, fixwordbreaks
from FileList import FileList
from ColorDelegator import ColorDelegator
from UndoDelegator import UndoDelegator
from OutputWindow import OutputWindow
from configHandler import idleConf
import idlever
import rpc
import Debugger
import RemoteDebugger
IDENTCHARS = string.ascii_letters + string.digits + '_'
LOCALHOST = '127.0.0.1'

try:
    from signal import SIGTERM
except ImportError:
    SIGTERM = 15

warning_stream = sys.__stderr__

try:
    import warnings
except ImportError:
    pass


def idle_showwarning(message, category, filename, lineno):
    file = warning_stream

    try:
        file.write(warnings.formatwarning(message, category, filename, lineno))
    except IOError:
        pass


warnings.showwarning = idle_showwarning

def idle_formatwarning(message, category, filename, lineno):
    '''Format warnings the IDLE way'''
    s = '\nWarning (from warnings module):\n'
    s += '  File "%s", line %s\n' % (filename, lineno)
    line = linecache.getline(filename, lineno).strip()
    if line:
        s += '    %s\n' % line

    s += '%s: %s\n>>> ' % (category.__name__, message)
    return s

warnings.formatwarning = idle_formatwarning

def extended_linecache_checkcache(filename = None, orig_checkcache = linecache.checkcache):
    '''Extend linecache.checkcache to preserve the <pyshell#...> entries

    Rather than repeating the linecache code, patch it to save the
    <pyshell#...> entries, call the original linecache.checkcache()
    (which destroys them), and then restore the saved entries.

    orig_checkcache is bound at definition time to the original
    method, allowing it to be patched.

    '''
    cache = linecache.cache
    save = { }
    for filename in cache.keys():
        if filename[:1] + filename[-1:] == '<>':
            save[filename] = cache[filename]
            continue

    orig_checkcache()
    cache.update(save)

linecache.checkcache = extended_linecache_checkcache

class PyShellEditorWindow(EditorWindow):
    '''Regular text edit window in IDLE, supports breakpoints'''

    def __init__(self, *args):
        self.breakpoints = []
        EditorWindow.__init__(self, *args)
        self.text.bind('<<set-breakpoint-here>>', self.set_breakpoint_here)
        self.text.bind('<<clear-breakpoint-here>>', self.clear_breakpoint_here)
        self.text.bind('<<open-python-shell>>', self.flist.open_shell)
        self.breakpointPath = os.path.join(idleConf.GetUserCfgDir(), 'breakpoints.lst')
        if self.io.filename:
            self.restore_file_breaks()


        def filename_changed_hook(old_hook = self.io.filename_change_hook, self = self):
            self.restore_file_breaks()
            old_hook()

        self.io.set_filename_change_hook(filename_changed_hook)

    rmenu_specs = [
        ('Set Breakpoint', '<<set-breakpoint-here>>'),
        ('Clear Breakpoint', '<<clear-breakpoint-here>>')]

    def set_breakpoint(self, lineno):
        text = self.text
        filename = self.io.filename
        text.tag_add('BREAK', '%d.0' % lineno, '%d.0' % (lineno + 1))

        try:
            i = self.breakpoints.index(lineno)
        except ValueError:
            self.breakpoints.append(lineno)


        try:
            debug = self.flist.pyshell.interp.debugger
            debug.set_breakpoint_here(filename, lineno)
        except:
            pass



    def set_breakpoint_here(self, event = None):
        text = self.text
        filename = self.io.filename
        if not filename:
            text.bell()
            return None

        lineno = int(float(text.index('insert')))
        self.set_breakpoint(lineno)


    def clear_breakpoint_here(self, event = None):
        text = self.text
        filename = self.io.filename
        if not filename:
            text.bell()
            return None

        lineno = int(float(text.index('insert')))

        try:
            self.breakpoints.remove(lineno)
        except:
            pass

        text.tag_remove('BREAK', 'insert linestart', 'insert lineend +1char')

        try:
            debug = self.flist.pyshell.interp.debugger
            debug.clear_breakpoint_here(filename, lineno)
        except:
            pass



    def clear_file_breaks(self):
        if self.breakpoints:
            text = self.text
            filename = self.io.filename
            if not filename:
                text.bell()
                return None

            self.breakpoints = []
            text.tag_remove('BREAK', '1.0', END)

            try:
                debug = self.flist.pyshell.interp.debugger
                debug.clear_file_breaks(filename)




    def store_file_breaks(self):
        '''Save breakpoints when file is saved'''
        breaks = self.breakpoints
        filename = self.io.filename

        try:
            lines = open(self.breakpointPath, 'r').readlines()
        except IOError:
            lines = []

        new_file = open(self.breakpointPath, 'w')
        for line in lines:
            if not line.startswith(filename + '='):
                new_file.write(line)
                continue

        self.update_breakpoints()
        breaks = self.breakpoints
        if breaks:
            new_file.write(filename + '=' + str(breaks) + '\n')

        new_file.close()


    def restore_file_breaks(self):
        self.text.update()
        filename = self.io.filename
        if filename is None:
            return None

        if os.path.isfile(self.breakpointPath):
            lines = open(self.breakpointPath, 'r').readlines()
            for line in lines:
                if line.startswith(filename + '='):
                    breakpoint_linenumbers = eval(line[len(filename) + 1:])
                    for breakpoint_linenumber in breakpoint_linenumbers:
                        self.set_breakpoint(breakpoint_linenumber)





    def update_breakpoints(self):
        '''Retrieves all the breakpoints in the current window'''
        text = self.text
        ranges = text.tag_ranges('BREAK')
        linenumber_list = self.ranges_to_linenumbers(ranges)
        self.breakpoints = linenumber_list


    def ranges_to_linenumbers(self, ranges):
        lines = []
        for index in range(0, len(ranges), 2):
            lineno = int(float(ranges[index]))
            end = int(float(ranges[index + 1]))
            while lineno < end:
                lines.append(lineno)
                lineno += 1

        return lines


    def _close(self):
        '''Extend base method - clear breaks when module is closed'''
        self.clear_file_breaks()
        EditorWindow._close(self)



class PyShellFileList(FileList):
    '''Extend base class: IDLE supports a shell and breakpoints'''
    EditorWindow = PyShellEditorWindow
    pyshell = None

    def open_shell(self, event = None):
        if self.pyshell:
            self.pyshell.top.wakeup()
        else:
            self.pyshell = PyShell(self)
            if self.pyshell:
                if not self.pyshell.begin():
                    return None


        return self.pyshell



class ModifiedColorDelegator(ColorDelegator):
    '''Extend base class: colorizer for the shell window itself'''

    def __init__(self):
        ColorDelegator.__init__(self)
        self.LoadTagDefs()


    def recolorize_main(self):
        self.tag_remove('TODO', '1.0', 'iomark')
        self.tag_add('SYNC', '1.0', 'iomark')
        ColorDelegator.recolorize_main(self)


    def LoadTagDefs(self):
        ColorDelegator.LoadTagDefs(self)
        theme = idleConf.GetOption('main', 'Theme', 'name')
        self.tagdefs.update({
            'stdin': {
                'background': None,
                'foreground': None },
            'stdout': idleConf.GetHighlight(theme, 'stdout'),
            'stderr': idleConf.GetHighlight(theme, 'stderr'),
            'console': idleConf.GetHighlight(theme, 'console'),
            None: idleConf.GetHighlight(theme, 'normal') })



class ModifiedUndoDelegator(UndoDelegator):
    '''Extend base class: forbid insert/delete before the I/O mark'''

    def insert(self, index, chars, tags = None):

        try:
            if self.delegate.compare(index, '<', 'iomark'):
                self.delegate.bell()
                return None
        except TclError:
            pass

        UndoDelegator.insert(self, index, chars, tags)


    def delete(self, index1, index2 = None):

        try:
            if self.delegate.compare(index1, '<', 'iomark'):
                self.delegate.bell()
                return None
        except TclError:
            pass

        UndoDelegator.delete(self, index1, index2)



class MyRPCClient(rpc.RPCClient):

    def handle_EOF(self):
        '''Override the base class - just re-raise EOFError'''
        raise EOFError



class ModifiedInterpreter(InteractiveInterpreter):

    def __init__(self, tkconsole):
        self.tkconsole = tkconsole
        locals = sys.modules['__main__'].__dict__
        InteractiveInterpreter.__init__(self, locals = locals)
        self.save_warnings_filters = None
        self.restarting = False
        self.subprocess_arglist = self.build_subprocess_arglist()

    port = 8833
    rpcclt = None
    rpcpid = None

    def spawn_subprocess(self):
        args = self.subprocess_arglist
        self.rpcpid = os.spawnv(os.P_NOWAIT, sys.executable, args)


    def build_subprocess_arglist(self):
        w = [ '-W' + s for s in sys.warnoptions ]
        del_exitf = idleConf.GetOption('main', 'General', 'delete-exitfunc', default = False, type = 'bool')
        if __name__ == 'idlelib.PyShell':
            command = "__import__('idlelib.run').run.main(%r)" % (del_exitf,)
        else:
            command = "__import__('run').main(%r)" % (del_exitf,)
        if sys.platform[:3] == 'win' and ' ' in sys.executable:
            decorated_exec = '"%s"' % sys.executable
        else:
            decorated_exec = sys.executable
        return [
            decorated_exec] + w + [
            '-c',
            command,
            str(self.port)]


    def start_subprocess(self):
        self.spawn_subprocess()
        addr = (LOCALHOST, self.port)
        for i in range(3):
            time.sleep(i)

            try:
                self.rpcclt = MyRPCClient(addr)
            continue
            except socket.error:
                err = None
                continue


        else:
            return None
        self.rpcclt.listening_sock.settimeout(10)

        try:
            self.rpcclt.accept()
        except socket.timeout:
            None<EXCEPTION MATCH>socket.error
            err = None<EXCEPTION MATCH>socket.error
            self.display_no_subprocess_error()
            return None
        except:
            None<EXCEPTION MATCH>socket.error

        self.rpcclt.register('stdin', self.tkconsole)
        self.rpcclt.register('stdout', self.tkconsole.stdout)
        self.rpcclt.register('stderr', self.tkconsole.stderr)
        self.rpcclt.register('flist', self.tkconsole.flist)
        self.rpcclt.register('linecache', linecache)
        self.rpcclt.register('interp', self)
        self.transfer_path()
        self.poll_subprocess()
        return self.rpcclt


    def restart_subprocess(self):
        if self.restarting:
            return self.rpcclt

        self.restarting = True
        debug = self.getdebugger()
        if debug:

            try:
                RemoteDebugger.close_subprocess_debugger(self.rpcclt)


        self.rpcclt.close()
        self.unix_terminate()
        console = self.tkconsole
        was_executing = console.executing
        console.executing = False
        self.spawn_subprocess()

        try:
            self.rpcclt.accept()
        except socket.timeout:
            err = None
            self.display_no_subprocess_error()
            return None

        self.transfer_path()
        console.text.delete('iomark', 'end-1c')
        if was_executing:
            console.write('\n')
            console.showprompt()

        halfbar = ((int(console.width) - 16) // 2) * '='
        console.write(halfbar + ' RESTART ' + halfbar)
        console.text.mark_set('restart', 'end-1c')
        console.text.mark_gravity('restart', 'left')
        console.showprompt()
        if debug:
            gui = RemoteDebugger.restart_subprocess_debugger(self.rpcclt)
            debug.load_breakpoints()

        self.restarting = False
        return self.rpcclt


    def __request_interrupt(self):
        self.rpcclt.remotecall('exec', 'interrupt_the_server', (), { })


    def interrupt_subprocess(self):
        threading.Thread(target = self._ModifiedInterpreter__request_interrupt).start()


    def kill_subprocess(self):

        try:
            self.rpcclt.close()
        except AttributeError:
            pass

        self.unix_terminate()
        self.tkconsole.executing = False
        self.rpcclt = None


    def unix_terminate(self):
        '''UNIX: make sure subprocess is terminated and collect status'''
        if hasattr(os, 'kill'):

            try:
                os.kill(self.rpcpid, SIGTERM)
            except OSError:
                return None


            try:
                os.waitpid(self.rpcpid, 0)
            except OSError:
                return None
            except:
                None<EXCEPTION MATCH>OSError


        None<EXCEPTION MATCH>OSError


    def transfer_path(self):
        self.runcommand('if 1:\n        import sys as _sys\n        _sys.path = %r\n        del _sys\n        \n' % (sys.path,))

    active_seq = None

    def poll_subprocess(self):
        clt = self.rpcclt
        if clt is None:
            return None


        try:
            response = clt.pollresponse(self.active_seq, wait = 0.05)
        except (EOFError, IOError, KeyboardInterrupt):
            if self.tkconsole.closing:
                return None

            response = None
            self.restart_subprocess()

        if response:
            self.tkconsole.resetoutput()
            self.active_seq = None
            (how, what) = response
            console = self.tkconsole.console
            if how == 'OK':
                if what is not None:
                    print >>console, repr(what)

            elif how == 'EXCEPTION':
                if self.tkconsole.getvar('<<toggle-jit-stack-viewer>>'):
                    self.remote_stack_viewer()

            elif how == 'ERROR':
                errmsg = 'PyShell.ModifiedInterpreter: Subprocess ERROR:\n'
                print >>sys.__stderr__, errmsg, what
                print >>console, errmsg, what


            try:
                self.tkconsole.endexecuting()
            except AttributeError:
                pass
            except:
                None<EXCEPTION MATCH>AttributeError


        None<EXCEPTION MATCH>AttributeError
        if not self.tkconsole.closing:
            self.tkconsole.text.after(self.tkconsole.pollinterval, self.poll_subprocess)


    debugger = None

    def setdebugger(self, debugger):
        self.debugger = debugger


    def getdebugger(self):
        return self.debugger


    def open_remote_stack_viewer(self):
        '''Initiate the remote stack viewer from a separate thread.

        This method is called from the subprocess, and by returning from this
        method we allow the subprocess to unblock.  After a bit the shell
        requests the subprocess to open the remote stack viewer which returns a
        static object looking at the last exceptiopn.  It is queried through
        the RPC mechanism.

        '''
        self.tkconsole.text.after(300, self.remote_stack_viewer)


    def remote_stack_viewer(self):
        import RemoteObjectBrowser
        oid = self.rpcclt.remotequeue('exec', 'stackviewer', ('flist',), { })
        if oid is None:
            self.tkconsole.root.bell()
            return None

        item = RemoteObjectBrowser.StubObjectTreeItem(self.rpcclt, oid)
        ScrolledCanvas = ScrolledCanvas
        TreeNode = TreeNode
        import TreeWidget
        top = Toplevel(self.tkconsole.root)
        theme = idleConf.GetOption('main', 'Theme', 'name')
        background = idleConf.GetHighlight(theme, 'normal')['background']
        sc = ScrolledCanvas(top, bg = background, highlightthickness = 0)
        sc.frame.pack(expand = 1, fill = 'both')
        node = TreeNode(sc.canvas, None, item)
        node.expand()

    gid = 0

    def execsource(self, source):
        '''Like runsource() but assumes complete exec source'''
        filename = self.stuffsource(source)
        self.execfile(filename, source)


    def execfile(self, filename, source = None):
        '''Execute an existing file'''
        if source is None:
            source = open(filename, 'r').read()


        try:
            code = compile(source, filename, 'exec')
        except (OverflowError, SyntaxError):
            self.tkconsole.resetoutput()
            tkerr = self.tkconsole.stderr
            print >>tkerr, '*** Error in script or command!\n'
            print >>tkerr, 'Traceback (most recent call last):'
            InteractiveInterpreter.showsyntaxerror(self, filename)
            self.tkconsole.showprompt()

        self.runcode(code)


    def runsource(self, source):
        '''Extend base class method: Stuff the source in the line cache first'''
        filename = self.stuffsource(source)
        self.more = 0
        self.save_warnings_filters = warnings.filters[:]
        warnings.filterwarnings(action = 'error', category = SyntaxWarning)
        if isinstance(source, types.UnicodeType):
            import IOBinding

            try:
                source = source.encode(IOBinding.encoding)
            except UnicodeError:
                self.tkconsole.resetoutput()
                self.write('Unsupported characters in input\n')
                return None
            except:
                None<EXCEPTION MATCH>UnicodeError


        None<EXCEPTION MATCH>UnicodeError

        try:
            return InteractiveInterpreter.runsource(self, source, filename)
        finally:
            if self.save_warnings_filters is not None:
                warnings.filters[:] = self.save_warnings_filters
                self.save_warnings_filters = None




    def stuffsource(self, source):
        '''Stuff source in the filename cache'''
        filename = '<pyshell#%d>' % self.gid
        self.gid = self.gid + 1
        lines = source.split('\n')
        linecache.cache[filename] = (len(source) + 1, 0, lines, filename)
        return filename


    def prepend_syspath(self, filename):
        """Prepend sys.path with file's directory if not already included"""
        self.runcommand('if 1:\n            _filename = %r\n            import sys as _sys\n            from os.path import dirname as _dirname\n            _dir = _dirname(_filename)\n            if not _dir in _sys.path:\n                _sys.path.insert(0, _dir)\n            del _filename, _sys, _dirname, _dir\n            \n' % (filename,))


    def showsyntaxerror(self, filename = None):
        '''Extend base class method: Add Colorizing

        Color the offending position instead of printing it and pointing at it
        with a caret.

        '''
        text = self.tkconsole.text
        stuff = self.unpackerror()
        if stuff:
            (msg, lineno, offset, line) = stuff
            if lineno == 1:
                pos = 'iomark + %d chars' % (offset - 1)
            else:
                pos = 'iomark linestart + %d lines + %d chars' % (lineno - 1, offset - 1)
            text.tag_add('ERROR', pos)
            text.see(pos)
            char = text.get(pos)
            if char and char in IDENTCHARS:
                text.tag_add('ERROR', pos + ' wordstart', pos)

            self.tkconsole.resetoutput()
            self.write('SyntaxError: %s\n' % str(msg))
        else:
            self.tkconsole.resetoutput()
            InteractiveInterpreter.showsyntaxerror(self, filename)
        self.tkconsole.showprompt()


    def unpackerror(self):
        (type, value, tb) = sys.exc_info()
        ok = type is SyntaxError
        if ok:

            try:
                (dummy_filename, lineno, offset, line) = (msg,)
                if not offset:
                    offset = 0
            ok = 0


        if ok:
            return (msg, lineno, offset, line)
        else:
            return None


    def showtraceback(self):
        '''Extend base class method to reset output properly'''
        self.tkconsole.resetoutput()
        self.checklinecache()
        InteractiveInterpreter.showtraceback(self)
        if self.tkconsole.getvar('<<toggle-jit-stack-viewer>>'):
            self.tkconsole.open_stack_viewer()



    def checklinecache(self):
        c = linecache.cache
        for key in c.keys():
            if key[:1] + key[-1:] != '<>':
                del c[key]
                continue



    def runcommand(self, code):
        '''Run the code without invoking the debugger'''
        if self.tkconsole.executing:
            self.display_executing_dialog()
            return 0

        if self.rpcclt:
            self.rpcclt.remotequeue('exec', 'runcode', (code,), { })
        else:
            exec code in self.locals
        return 1


    def runcode(self, code):
        '''Override base class method'''
        if self.tkconsole.executing:
            self.interp.restart_subprocess()

        self.checklinecache()
        if self.save_warnings_filters is not None:
            warnings.filters[:] = self.save_warnings_filters
            self.save_warnings_filters = None

        debugger = self.debugger

        try:
            self.tkconsole.beginexecuting()

            try:
                if not debugger and self.rpcclt is not None:
                    self.active_seq = self.rpcclt.asyncqueue('exec', 'runcode', (code,), { })
                elif debugger:
                    debugger.run(code, self.locals)
                else:
                    exec code in self.locals
            except SystemExit:
                if not self.tkconsole.closing:
                    if tkMessageBox.askyesno('Exit?', 'Do you want to exit altogether?', default = 'yes', master = self.tkconsole.text):
                        raise
                    else:
                        self.showtraceback()
                else:
                    raise
            except:
                self.tkconsole.closing
                if use_subprocess:
                    print >>self.tkconsole.stderr, 'IDLE internal error in runcode()'

                self.showtraceback()
                if use_subprocess:
                    self.tkconsole.endexecuting()


        finally:
            if not use_subprocess:

                try:
                    self.tkconsole.endexecuting()
                except AttributeError:
                    pass
                except:
                    None<EXCEPTION MATCH>AttributeError





    def write(self, s):
        '''Override base class method'''
        self.tkconsole.stderr.write(s)


    def display_port_binding_error(self):
        tkMessageBox.showerror('Port Binding Error', "IDLE can't bind TCP/IP port 8833, which is necessary to communicate with its Python execution server.  Either no networking is installed on this computer or another process (another IDLE?) is using the port.  Run IDLE with the -n command line switch to start without a subprocess and refer to Help/IDLE Help 'Running without a subprocess' for further details.", master = self.tkconsole.text)


    def display_no_subprocess_error(self):
        tkMessageBox.showerror('Subprocess Startup Error', "IDLE's subprocess didn't make connection.  Either IDLE can't start a subprocess or personal firewall software is blocking the connection.", master = self.tkconsole.text)


    def display_executing_dialog(self):
        tkMessageBox.showerror('Already executing', 'The Python Shell window is already executing a command; please wait until it is finished.', master = self.tkconsole.text)



class PyShell(OutputWindow):
    shell_title = 'Python Shell'
    ColorDelegator = ModifiedColorDelegator
    UndoDelegator = ModifiedUndoDelegator
    menu_specs = [
        ('file', '_File'),
        ('edit', '_Edit'),
        ('debug', '_Debug'),
        ('options', '_Options'),
        ('windows', '_Windows'),
        ('help', '_Help')]
    if macosxSupport.runningAsOSXApp():
        del menu_specs[-3]
        menu_specs[-2] = ('windows', '_Window')

    from IdleHistory import History

    def __init__(self, flist = None):
        if use_subprocess:
            ms = self.menu_specs
            if ms[2][0] != 'shell':
                ms.insert(2, ('shell', 'She_ll'))


        self.interp = ModifiedInterpreter(self)
        if flist is None:
            root = Tk()
            fixwordbreaks(root)
            root.withdraw()
            flist = PyShellFileList(root)

        OutputWindow.__init__(self, flist, None, None)
        self.usetabs = True
        self.indentwidth = 8
        self.context_use_ps1 = True
        text = self.text
        text.configure(wrap = 'char')
        text.bind('<<newline-and-indent>>', self.enter_callback)
        text.bind('<<plain-newline-and-indent>>', self.linefeed_callback)
        text.bind('<<interrupt-execution>>', self.cancel_callback)
        text.bind('<<beginning-of-line>>', self.home_callback)
        text.bind('<<end-of-file>>', self.eof_callback)
        text.bind('<<open-stack-viewer>>', self.open_stack_viewer)
        text.bind('<<toggle-debugger>>', self.toggle_debugger)
        text.bind('<<toggle-jit-stack-viewer>>', self.toggle_jit_stack_viewer)
        if use_subprocess:
            text.bind('<<view-restart>>', self.view_restart_mark)
            text.bind('<<restart-shell>>', self.restart_shell)

        self.save_stdout = sys.stdout
        self.save_stderr = sys.stderr
        self.save_stdin = sys.stdin
        import IOBinding
        self.stdout = PseudoFile(self, 'stdout', IOBinding.encoding)
        self.stderr = PseudoFile(self, 'stderr', IOBinding.encoding)
        self.console = PseudoFile(self, 'console', IOBinding.encoding)
        if not use_subprocess:
            sys.stdout = self.stdout
            sys.stderr = self.stderr
            sys.stdin = self

        self.history = self.History(self.text)
        self.pollinterval = 50


    def get_standard_extension_names(self):
        return idleConf.GetExtensions(shell_only = True)

    reading = False
    executing = False
    canceled = False
    endoffile = False
    closing = False

    def set_warning_stream(self, stream):
        global warning_stream
        warning_stream = stream


    def get_warning_stream(self):
        return warning_stream


    def toggle_debugger(self, event = None):
        if self.executing:
            tkMessageBox.showerror("Don't debug now", 'You can only toggle the debugger when idle', master = self.text)
            self.set_debugger_indicator()
            return 'break'
        else:
            db = self.interp.getdebugger()
            if db:
                self.close_debugger()
            else:
                self.open_debugger()


    def set_debugger_indicator(self):
        db = self.interp.getdebugger()
        self.setvar('<<toggle-debugger>>', not (not db))


    def toggle_jit_stack_viewer(self, event = None):
        pass


    def close_debugger(self):
        db = self.interp.getdebugger()
        if db:
            self.interp.setdebugger(None)
            db.close()
            if self.interp.rpcclt:
                RemoteDebugger.close_remote_debugger(self.interp.rpcclt)

            self.resetoutput()
            self.console.write('[DEBUG OFF]\n')
            sys.ps1 = '>>> '
            self.showprompt()

        self.set_debugger_indicator()


    def open_debugger(self):
        if self.interp.rpcclt:
            dbg_gui = RemoteDebugger.start_remote_debugger(self.interp.rpcclt, self)
        else:
            dbg_gui = Debugger.Debugger(self)
        self.interp.setdebugger(dbg_gui)
        dbg_gui.load_breakpoints()
        sys.ps1 = '[DEBUG ON]\n>>> '
        self.showprompt()
        self.set_debugger_indicator()


    def beginexecuting(self):
        '''Helper for ModifiedInterpreter'''
        self.resetoutput()
        self.executing = 1


    def endexecuting(self):
        '''Helper for ModifiedInterpreter'''
        self.executing = 0
        self.canceled = 0
        self.showprompt()


    def close(self):
        '''Extend EditorWindow.close()'''
        if self.executing:
            response = tkMessageBox.askokcancel('Kill?', 'The program is still running!\n Do you want to kill it?', default = 'ok', parent = self.text)
            if response == False:
                return 'cancel'


        if self.reading:
            self.top.quit()

        self.canceled = True
        self.closing = True
        self.text.after(2 * self.pollinterval, self.close2)


    def close2(self):
        return EditorWindow.close(self)


    def _close(self):
        '''Extend EditorWindow._close(), shut down debugger and execution server'''
        self.close_debugger()
        if use_subprocess:
            self.interp.kill_subprocess()

        sys.stdout = self.save_stdout
        sys.stderr = self.save_stderr
        sys.stdin = self.save_stdin
        self.interp = None
        self.console = None
        self.flist.pyshell = None
        self.history = None
        EditorWindow._close(self)


    def ispythonsource(self, filename):
        '''Override EditorWindow method: never remove the colorizer'''
        return True


    def short_title(self):
        return self.shell_title

    COPYRIGHT = 'Type "copyright", "credits" or "license()" for more information.'
    firewallmessage = "\n    ****************************************************************\n    Personal firewall software may warn about the connection IDLE\n    makes to its subprocess using this computer's internal loopback\n    interface.  This connection is not visible on any external\n    interface and no data is sent to or received from the Internet.\n    ****************************************************************\n    "

    def begin(self):
        self.resetoutput()
        if use_subprocess:
            nosub = ''
            client = self.interp.start_subprocess()
            if not client:
                self.close()
                return False

        else:
            nosub = '==== No Subprocess ===='
        self.write('Python %s on %s\n%s\n%s\nIDLE %s      %s\n' % (sys.version, sys.platform, self.COPYRIGHT, self.firewallmessage, idlever.IDLE_VERSION, nosub))
        self.showprompt()
        import Tkinter
        Tkinter._default_root = None
        return True


    def readline(self):
        save = self.reading

        try:
            self.reading = 1
            self.top.mainloop()
        finally:
            self.reading = save

        line = self.text.get('iomark', 'end-1c')
        if len(line) == 0:
            line = '\n'

        if isinstance(line, unicode):
            import IOBinding

            try:
                line = line.encode(IOBinding.encoding)
            except UnicodeError:
                pass
            except:
                None<EXCEPTION MATCH>UnicodeError


        None<EXCEPTION MATCH>UnicodeError
        self.resetoutput()
        if self.canceled:
            self.canceled = 0
            if not use_subprocess:
                raise KeyboardInterrupt


        if self.endoffile:
            self.endoffile = 0
            line = ''

        return line


    def isatty(self):
        return True


    def cancel_callback(self, event = None):

        try:
            if self.text.compare('sel.first', '!=', 'sel.last'):
                return None
        except:
            pass

        if not self.executing or self.reading:
            self.resetoutput()
            self.interp.write('KeyboardInterrupt\n')
            self.showprompt()
            return 'break'

        self.endoffile = 0
        self.canceled = 1
        if self.executing and self.interp.rpcclt:
            if self.interp.getdebugger():
                self.interp.restart_subprocess()
            else:
                self.interp.interrupt_subprocess()

        if self.reading:
            self.top.quit()

        return 'break'


    def eof_callback(self, event):
        if self.executing and not (self.reading):
            return None

        if not self.text.compare('iomark', '==', 'insert') and self.text.compare('insert', '==', 'end-1c'):
            return None

        if not self.executing:
            self.resetoutput()
            self.close()
        else:
            self.canceled = 0
            self.endoffile = 1
            self.top.quit()
        return 'break'


    def home_callback(self, event):
        if event.state != 0 and event.keysym == 'Home':
            return None

        if self.text.compare('iomark', '<=', 'insert') and self.text.compare('insert linestart', '<=', 'iomark'):
            self.text.mark_set('insert', 'iomark')
            self.text.tag_remove('sel', '1.0', 'end')
            self.text.see('insert')
            return 'break'



    def linefeed_callback(self, event):
        if self.reading:
            self.text.insert('insert', '\n')
            self.text.see('insert')
        else:
            self.newline_and_indent_event(event)
        return 'break'


    def enter_callback(self, event):
        if self.executing and not (self.reading):
            return None


        try:
            sel = self.text.get('sel.first', 'sel.last')
            if sel:
                if self.text.compare('sel.last', '<=', 'iomark'):
                    self.recall(sel, event)
                    return 'break'

        except:
            pass

        if self.text.compare('insert', '<', 'iomark linestart'):
            prev = self.text.tag_prevrange('stdin', 'insert')
            if prev and self.text.compare('insert', '<', prev[1]):
                self.recall(self.text.get(prev[0], prev[1]), event)
                return 'break'

            next = self.text.tag_nextrange('stdin', 'insert')
            if next and self.text.compare('insert lineend', '>=', next[0]):
                self.recall(self.text.get(next[0], next[1]), event)
                return 'break'

            indices = self.text.tag_nextrange('console', 'insert linestart')
            if indices and self.text.compare(indices[0], '<=', 'insert linestart'):
                self.recall(self.text.get(indices[1], 'insert lineend'), event)
            else:
                self.recall(self.text.get('insert linestart', 'insert lineend'), event)
            return 'break'

        if self.text.compare('insert', '<', 'iomark'):
            self.text.mark_set('insert', 'iomark')

        s = self.text.get('insert', 'end-1c')
        if s and not s.strip():
            self.text.delete('insert', 'end-1c')

        if self.text.compare('insert', '<', 'end-1c linestart'):
            self.newline_and_indent_event(event)
            return 'break'

        self.text.mark_set('insert', 'end-1c')
        if self.reading:
            self.text.insert('insert', '\n')
            self.text.see('insert')
        else:
            self.newline_and_indent_event(event)
        self.text.tag_add('stdin', 'iomark', 'end-1c')
        self.text.update_idletasks()
        if self.reading:
            self.top.quit()
        else:
            self.runit()
        return 'break'


    def recall(self, s, event):
        s = re.sub('^\\s*\\n', '', s)
        s = re.sub('\\n\\s*$', '', s)
        lines = s.split('\n')
        self.text.undo_block_start()

        try:
            self.text.tag_remove('sel', '1.0', 'end')
            self.text.mark_set('insert', 'end-1c')
            prefix = self.text.get('insert linestart', 'insert')
            if prefix.rstrip().endswith(':'):
                self.newline_and_indent_event(event)
                prefix = self.text.get('insert linestart', 'insert')

            self.text.insert('insert', lines[0].strip())
            if len(lines) > 1:
                orig_base_indent = re.search('^([ \\t]*)', lines[0]).group(0)
                new_base_indent = re.search('^([ \\t]*)', prefix).group(0)
                for line in lines[1:]:
                    if line.startswith(orig_base_indent):
                        line = new_base_indent + line[len(orig_base_indent):]

                    self.text.insert('insert', '\n' + line.rstrip())

        finally:
            self.text.see('insert')
            self.text.undo_block_stop()



    def runit(self):
        line = self.text.get('iomark', 'end-1c')
        i = len(line)
        while i > 0 and line[i - 1] in ' \t':
            i = i - 1
        if i > 0 and line[i - 1] == '\n':
            i = i - 1

        while i > 0 and line[i - 1] in ' \t':
            i = i - 1
        line = line[:i]
        more = self.interp.runsource(line)


    def open_stack_viewer(self, event = None):
        if self.interp.rpcclt:
            return self.interp.remote_stack_viewer()


        try:
            sys.last_traceback
        except:
            tkMessageBox.showerror('No stack trace', 'There is no stack trace yet.\n(sys.last_traceback is not defined)', master = self.text)
            return None

        StackBrowser = StackBrowser
        import StackViewer
        sv = StackBrowser(self.root, self.flist)


    def view_restart_mark(self, event = None):
        self.text.see('iomark')
        self.text.see('restart')


    def restart_shell(self, event = None):
        self.interp.restart_subprocess()


    def showprompt(self):
        self.resetoutput()

        try:
            s = str(sys.ps1)
        except:
            s = ''

        self.console.write(s)
        self.text.mark_set('insert', 'end-1c')
        self.set_line_and_column()
        self.io.reset_undo()


    def resetoutput(self):
        source = self.text.get('iomark', 'end-1c')
        if self.history:
            self.history.history_store(source)

        if self.text.get('end-2c') != '\n':
            self.text.insert('end-1c', '\n')

        self.text.mark_set('iomark', 'end-1c')
        self.set_line_and_column()
        sys.stdout.softspace = 0


    def write(self, s, tags = ()):

        try:
            self.text.mark_gravity('iomark', 'right')
            OutputWindow.write(self, s, tags, 'iomark')
            self.text.mark_gravity('iomark', 'left')
        except:
            pass

        if self.canceled:
            self.canceled = 0
            if not use_subprocess:
                raise KeyboardInterrupt





class PseudoFile(object):

    def __init__(self, shell, tags, encoding = None):
        self.shell = shell
        self.tags = tags
        self.softspace = 0
        self.encoding = encoding


    def write(self, s):
        self.shell.write(s, self.tags)


    def writelines(self, l):
        map(self.write, l)


    def flush(self):
        pass


    def isatty(self):
        return True


usage_msg = '\nUSAGE: idle  [-deins] [-t title] [file]*\n       idle  [-dns] [-t title] (-c cmd | -r file) [arg]*\n       idle  [-dns] [-t title] - [arg]*\n\n  -h         print this help message and exit\n  -n         run IDLE without a subprocess (see Help/IDLE Help for details)\n\nThe following options will override the IDLE \'settings\' configuration:\n\n  -e         open an edit window\n  -i         open a shell window\n\nThe following options imply -i and will open a shell:\n\n  -c cmd     run the command in a shell, or\n  -r file    run script from file\n\n  -d         enable the debugger\n  -s         run $IDLESTARTUP or $PYTHONSTARTUP before anything else\n  -t title   set title of shell window\n\nA default edit window will be bypassed when -c, -r, or - are used.\n\n[arg]* are passed to the command (-c) or script (-r) in sys.argv[1:].\n\nExamples:\n\nidle\n        Open an edit window or shell depending on IDLE\'s configuration.\n\nidle foo.py foobar.py\n        Edit the files, also open a shell if configured to start with shell.\n\nidle -est "Baz" foo.py\n        Run $IDLESTARTUP or $PYTHONSTARTUP, edit foo.py, and open a shell\n        window with the title "Baz".\n\nidle -c "import sys; print sys.argv" "foo"\n        Open a shell window and run the command, passing "-c" in sys.argv[0]\n        and "foo" in sys.argv[1].\n\nidle -d -s -r foo.py "Hello World"\n        Open a shell window, run a startup script, enable the debugger, and\n        run foo.py, passing "foo.py" in sys.argv[0] and "Hello World" in\n        sys.argv[1].\n\necho "import sys; print sys.argv" | idle - "foobar"\n        Open a shell window, run the script piped in, passing \'\' in sys.argv[0]\n        and "foobar" in sys.argv[1].\n'

def main():
    global use_subprocess, use_subprocess, root, flist
    use_subprocess = True
    enable_shell = False
    enable_edit = False
    debug = False
    cmd = None
    script = None
    startup = False

    try:
        (opts, args) = getopt.getopt(sys.argv[1:], 'c:deihnr:st:')
    except getopt.error:
        msg = None
        sys.stderr.write('Error: %s\n' % str(msg))
        sys.stderr.write(usage_msg)
        sys.exit(2)

    for o, a in opts:
        if o == '-c':
            cmd = a
            enable_shell = True

        if o == '-d':
            debug = True
            enable_shell = True

        if o == '-e':
            enable_edit = True

        if o == '-h':
            sys.stdout.write(usage_msg)
            sys.exit()

        if o == '-i':
            enable_shell = True

        if o == '-n':
            use_subprocess = False

        if o == '-r':
            script = a
            if os.path.isfile(script):
                pass
            else:
                print 'No script file: ', script
                sys.exit()
            enable_shell = True

        if o == '-s':
            startup = True
            enable_shell = True

        if o == '-t':
            PyShell.shell_title = a
            enable_shell = True
            continue

    if args and args[0] == '-':
        cmd = sys.stdin.read()
        enable_shell = True

    for i in range(len(sys.path)):
        sys.path[i] = os.path.abspath(sys.path[i])

    if args and args[0] == '-':
        sys.argv = [
            ''] + args[1:]
    elif cmd:
        sys.argv = [
            '-c'] + args
    elif script:
        sys.argv = [
            script] + args
    elif args:
        enable_edit = True
        pathx = []
        for filename in args:
            pathx.append(os.path.dirname(filename))

        for dir in pathx:
            dir = os.path.abspath(dir)
            if dir not in sys.path:
                sys.path.insert(0, dir)
                continue

    else:
        dir = os.getcwd()
        if dir not in sys.path:
            sys.path.insert(0, dir)

    edit_start = idleConf.GetOption('main', 'General', 'editor-on-startup', type = 'bool')
    if not enable_edit:
        pass
    enable_edit = edit_start
    if not enable_shell:
        pass
    enable_shell = not edit_start
    root = Tk(className = 'Idle')
    fixwordbreaks(root)
    root.withdraw()
    flist = PyShellFileList(root)
    macosxSupport.setupApp(root, flist)
    if enable_edit:
        if not cmd or script:
            for filename in args:
                flist.open(filename)

            if not args:
                flist.new()



    if enable_shell:
        shell = flist.open_shell()
        if not shell:
            return None

        if macosxSupport.runningAsOSXApp() and flist.dict:
            shell.top.lower()


    shell = flist.pyshell
    if debug:
        shell.open_debugger()

    if startup:
        if not os.environ.get('IDLESTARTUP'):
            pass
        filename = os.environ.get('PYTHONSTARTUP')
        if filename and os.path.isfile(filename):
            shell.interp.execfile(filename)


    if shell or cmd or script:
        shell.interp.runcommand('if 1:\n            import sys as _sys\n            _sys.argv = %r\n            del _sys\n            \n' % (sys.argv,))
        if cmd:
            shell.interp.execsource(cmd)
        elif script:
            shell.interp.prepend_syspath(script)
            shell.interp.execfile(script)


    root.mainloop()
    root.destroy()

if __name__ == '__main__':
    sys.modules['PyShell'] = sys.modules['__main__']
    main()